import sys, gc, threading, asyncio
assert not sys._is_gil_enabled()

N, ITERS = 4, 6000
barrier = threading.Barrier(N)


def leftover():
    1/0

async def inner():
    try:
        return asyncio.create_task(leftover)
    except Exception as exc:
        # print(exc)
        pass


async def outer():
    for i in range(ITERS):
        await inner()
        gc.collect()

def worker():
    barrier.wait()
    asyncio.run(outer())
    
ts = [threading.Thread(target=worker) for _ in range(N)]
for t in ts: t.start()
for t in ts: t.join()